package com.example.mq.common;


import lombok.Data;

/**
 * 表示一个消费者（完整的消费环境）
 */

@Data
public class ConsumerEnv {
    private String consumeTag;
    private String queueName;
    private boolean autoAck;
    // 通过这个回调函数来处理收到的消息
    private Consumer consumer;

    public ConsumerEnv(String consumeTag, String queueName, boolean autoAck, Consumer consumer) {
        this.consumeTag = consumeTag;
        this.queueName = queueName;
        this.autoAck = autoAck;
        this.consumer = consumer;
    }
}
